package com.example.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.example.po.SysMQMessage;

import java.util.List;

/*
 * @className: SysMQMessageService
 * @author: chentao
 * @date: 2025/2/28 下午5:17
 * @Version: 1.0
 * @description:
 */
public interface SysMQMessageService extends IService<SysMQMessage> {

    public List<SysMQMessage> getSysMQMessage(Long serverKey, int maxSize, int maxRetryCount);

    public int getSysMQMessageTotalSize(Long serverKey);

    public void updateMessageServer(Long sourceServerKey, Long targetServerKey);

    public void updateMessageServer(Long targetServerKey, int countSize);

    public void updateMessageServerBatch(Long sourceServerKey, Long targetServerKey, int index, int total);

    public List<Long> getDeathMessageServerExcept(List<Long> activeServerKeys);

    public List<Long> getAllDeathMessageServer();
}
